package org.jeecg.modules.mqtt;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * @program: simulator-b20240918
 * @description:
 * @author: renzhg
 * @create: 2024-10-28 11:03
 **/
@Component
@Data
public class MQTTConfig {

    /**
     * host 服务器地址配置
     */
//    @Value("${mqtt.host}")
    @Value("tcp://10.240.9.18:1883")
    private String[] host;

    /**
     * clientId
     */
//    @Value("${mqtt.clientId}")
    @Value("COCC_MQTT_MK")
    private String clientId;

    /**
     * 订阅的主题
     */
//    @Value("${mqtt.topics}")
    @Value("topic1,topic2,topic2/topic22/#")
    private String[] topics;

    /**
     * 用户名
     */
//    @Value("${mqtt.username}")
    @Value("coccyj")
    private String username;

    /**
     * 密码
     */
//    @Value("${mqtt.password}")
    @Value("12345@ssdlh")
    private String password;

    /**
     * 连接超时时长
     */
//    @Value("${mqtt.timeout}")
    @Value("30")
    private Integer timeout;

    /**
     * keep Alive时间(心跳检测)
     */
//    @Value("${mqtt.keepalive}")
    @Value("60")
    private Integer keepalive;

    /**
     * 默认QoS
     */
//    @Value("${mqtt.qos}")
    @Value("1")
    private Integer qos;


    /**
     * false为建立持久会话
     */
//    @Value("${mqtt.cleanSession}")
    @Value("false")
    private Boolean cleanSession;

    /**
     * 断开后重新连接
     */
//    @Value("${mqtt.automaticReconnect}")
    @Value("true")
    private Boolean automaticReconnect;
}
